package com.peter.springcloud.streamclient.client;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface RabbitClient { // 消息接收发送的接口
    public final static String INPUT = "myInput";
    public final static String OUTPUT = "myOutput";

    @Input(INPUT) // 绑定消息读取管道
    SubscribableChannel input(); // 获取接收消息的管道

    @Output(OUTPUT) // 绑定消息写出的管道。
    MessageChannel output(); // 获取写出消息的管道
}
